#!coding=utf-8
#创建并配置Celery应用，以及定义一个简单的加法任务。该函数接受两个参数，分别为当前脚本的名称和broker服务地址。然后定义一个名为add的Celery任务，该任务接受两个参数x和y，返回它们的和。

from celery import Celery

# 第一个参数 是当前脚本的名称，第二个参数 是 broker 服务地址
app = Celery('tasks', backend='redis://127.0.0.1', broker='redis://127.0.0.1')


@app.task
def add(x, y):
    return x + y
